package com.daling.product_processor.service;

import com.daling.product_processor.dao.bean.V3Product;

public class AdaptorDrfyxAppletsDrf implements Adaptor{

    @Override
    public V3Product process(String line, Integer sourceCode, String shopCode) {
        String csvSplitBy = ",";

        try {
            // 读取每一行数据（即每一个商品）
            String[] item = line.split(csvSplitBy);
            String name = item[0];
            Integer price = Integer.valueOf(item[1]);
            Integer isSale = Integer.valueOf(item[2]);
            String weight = item[3];
            String pics = item[4];
            String unit = item[5];
            String cateId = item[6];
            String cateName = item[7];

            // 对每一个字段的值进行处理
//            Integer priceAf = ProcessFields.processPrice(price);

            // 处理每一个商品的字段信息输出为`productV3`bean
            V3Product v3Product = new V3Product();
            v3Product.setName(name);
            v3Product.setPrice(price);
            v3Product.setIsSale(isSale);
            v3Product.setWeight(weight);
            v3Product.setPics(pics);
            v3Product.setUnit(unit);
            v3Product.setCateId(cateId);
            v3Product.setCateName(cateName);


            // 数据库操作
            // 查询数据库是否有该数据(商品名、数据来源ID、门店编码 为组合唯一键)
            V3Product v3ProQuery = new V3Product();
            v3ProQuery.setName(name);
            v3ProQuery.setSource(sourceCode);
            v3ProQuery.setShopCode(shopCode);
//            int count = v3proModel.getCountV3Product(v3ProQuery);
//
//            if (count==0) {  // insert
//                v3proModel.insertV3Product(v3Product);
//            } else {  // update
//                Integer id = v3ProQuery.getId();
//                v3proModel.updateV3Product(v3Product);
//            }


            // 存储数据至数据库v3_product



        } catch (Exception e) {
            e.printStackTrace();
        }

        return null;
    }
}
